
    <!DOCTYPE html>
    <html lang="zh-CN">
    <head>
      <meta charset="UTF-8">
      <meta name="viewport" content="width=device-width, initial-scale=1.0">
      <title>Kafka的生产者与消费者模型 - 学习卡片</title>
      <style>
        body { font-family: sans-serif; background-color: #f0f8ff; color: #333; display: flex; flex-direction: column; align-items: center; padding: 50px 20px; }
        .header h1 { font-size: 32px; }
        .grid-container { display: grid; grid-template-columns: repeat(3, 1fr); gap: 28px; width: 100%; max-width: 1200px; }
        .card-container { perspective: 1200px; cursor: pointer; height: 250px; }
        .card { width: 100%; height: 100%; position: relative; transform-style: preserve-3d; transition: transform 0.7s; border-radius: 16px; box-shadow: 0 4px 16px rgba(0,0,0,0.08); }
        .card-container.flipped .card { transform: rotateY(180deg); }
        .card-face { position: absolute; width: 100%; height: 100%; backface-visibility: hidden; display: flex; flex-direction: column; box-sizing: border-box; border-radius: 16px; background-color: #fff; padding: 24px; }
        .card-back { background-color: #f0fff4; transform: rotateY(180deg); justify-content: space-between; }
        .card-category { font-size: 14px; color: #0052d9; margin-bottom: 8px; font-weight: 500; }
        .card-question { font-size: 20px; font-weight: 500; flex-grow: 1; display: flex; align-items: center; justify-content: center; text-align: center; }
        .card-answer-wrapper { flex-grow: 1; overflow-y: auto; }
        .card-answer { font-size: 15px; line-height: 1.7; }
        .card-footer { font-size: 13px; color: #8a919f; border-top: 1px solid #f0f0f0; padding-top: 16px; margin-top: 16px; }
        .card-source { font-size: 13px; color: #8a919f; border-top: 1px solid #f0f0f0; padding-top: 12px; margin-top: 12px; }
      </style>
    </head>
    <body>
      <div class="header">
        <h1>Kafka的生产者与消费者模型 - 学习卡片</h1>
      </div>
      <div class="grid-container">
        
    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">技术</div>
          <div class="card-question">在Kafka中，有哪些关键参数或方法可以用来优化生产者的吞吐量？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">技术</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">优化生产者吞吐量的关键方法包括：1. 通过设置较大的 `batch.size` 进行批量发送；2. 使用 `compression.type` 参数开启消息压缩（如Snappy, Gzip）；3. 采用 `send()` 方法进行异步发送以降低阻塞。</div>
          </div>
          <div class="card-source">来源: 一、生产者模型优化 -> 1. 吞吐量优化</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">机制</div>
          <div class="card-question">Kafka生产者配置中的`acks`参数有哪三种主要设置？它们分别代表什么级别的可靠性？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">机制</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">`acks`参数有三种设置：`acks=0` 表示最快但最不可靠；`acks=1` 表示主副本确认后返回，可靠性较高；`acks=all` 表示所有ISR（In-Sync Replicas）副本确认后返回，可靠性最高。</div>
          </div>
          <div class="card-source">来源: 一、生产者模型优化 -> 3. 数据可靠性优化</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">特性</div>
          <div class="card-question">当Kafka生产者因网络问题重试发送消息时，如何防止消息在分区中被重复写入？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">特性</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">通过启用生产者幂等性（设置 `enable.idempotence=true`），可以确保即使消息因重试而被重复发送，也不会在分区中被重复写入。</div>
          </div>
          <div class="card-source">来源: 一、生产者模型优化 -> 3. 数据可靠性优化</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">技术</div>
          <div class="card-question">提升Kafka消费者吞吐量的主要方法有哪些？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">技术</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">主要方法包括：1. 使用多线程或增加消费者实例进行并发消费（消费者数量不超过分区数）；2. 配置较大的 `fetch.min.bytes` 和 `fetch.max.bytes` 参数来批量拉取消息；3. 根据业务需求选择合适的分区分配策略（如Range, RoundRobin, Sticky）。</div>
          </div>
          <div class="card-source">来源: 二、消费者模型优化 -> 1. 消费效率优化</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">模式</div>
          <div class="card-question">为确保消息在消费端不丢失、不重复，文档推荐如何管理消费者的偏移量（offset）？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">模式</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">文档推荐将 `enable.auto.commit` 设置为 `false`，并在消息处理成功后手动提交偏移量。这可以确保消费的幂等性，避免因自动提交时机不当导致的数据问题。</div>
          </div>
          <div class="card-source">来源: 二、消费者模型优化 -> 2. 数据可靠性与准确性</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">机制</div>
          <div class="card-question">如果消费者处理消息失败，文档中建议采用什么机制来处理这些失败的消息？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">机制</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">文档建议设计消费重试机制，例如通过设置一个死信队列（Dead Letter Queue）来专门存储处理失败的消息，以便后续分析和处理。</div>
          </div>
          <div class="card-source">来源: 二、消费者模型优化 -> 2. 数据可靠性与准确性</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">理论</div>
          <div class="card-question">在设计Kafka消费者组时，消费者实例数量和主题分区数量之间存在什么关系？为什么？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">理论</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">消费者实例的数量不应超过主题的分区数。因为一个分区最多只能被同一个消费者组内的一个消费者实例消费，如果消费者数量多于分区数，多余的消费者将会闲置，造成资源浪费。</div>
          </div>
          <div class="card-source">来源: 二、消费者模型优化 -> 1. 消费效率优化</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">特性</div>
          <div class="card-question">在高可靠性场景下，如何利用Kafka的事务特性来保证生产者和消费者之间的数据一致性？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">特性</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">生产者可以启用事务，这需要设置 `enable.idempotence=true` 并且配置一个事务ID。通过这种方式，可以确保消息在生产和消费过程中的数据一致性。</div>
          </div>
          <div class="card-source">来源: 三、生产者与消费者的协同优化 -> 4. 幂等性与事务支持</div>
        </div>
      </div>
    </div>

    <div class="card-container" onclick="this.classList.toggle('flipped');">
      <div class="card">
        <div class="card-face card-front">
          <div class="card-category">模式</div>
          <div class="card-question">为了实现Kafka分区的负载均衡并避免热点分区，可以采用什么策略？</div>
          <div class="card-footer">点击卡片查看答案</div>
        </div>
        <div class="card-face card-back">
          <div class="card-category">模式</div>
          <div class="card-answer-wrapper">
            <div class="card-answer">文档提到可以使用一致性哈希或其他负载均衡策略，来确保消息在各个分区间能够均匀分布，从而避免负载集中在少数分区上。</div>
          </div>
          <div class="card-source">来源: 三、生产者与消费者的协同优化 -> 3. 负载均衡</div>
        </div>
      </div>
    </div>

      </div>
    </body>
    </html>
